package com.biye.auth.tool.rabbitProvider.dao;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @Author Maple.Chen
 * @Description 活动课程抢课
 * @Date 20:05 2021/3/1
 **/
public interface HuoDongCourseDao {

    String OUTPUT = "huo_dong";

    @Output(value = "huo_dong")
    MessageChannel output1();

    /*
    # spring.cloud.stream.bindings.[output].destination:         交换机的名称
    # spring.cloud.stream.bindings.[output].group:               输出组，用于生成队列，组名相同时可以实现分布式[重写Source.class]
    # spring.cloud.stream.bindings.[input].destination:          交换机的名称
    # spring.cloud.stream.bindings.[input].group:                接收组，用于生成队列，组名相同时可以实现分布式[重写Sink.class]
    # spring.cloud.stream.bindings.[input].consumer.concurrency: 消费者的并发量
    # spring.rabbitmq.addresses:                                 服务器地址
    # spring.rabbitmq.username:                                  账号
    # spring.rabbitmq.password:                                  密码
    # spring.rabbitmq.virtual-host:                              虚拟主机
     */

}
